02a9e3507b7c7afd2dc8e90153a1dc1721022617,camel-core/src/main/java/org/apache/camel/model/LoadBalanceType.java,LoadBalanceType,createProcessor,#RouteContext#,127
Before Change
LoadBalancer loadBalancer = LoadBalancerType.getLoadBalancer(routeContext, loadBalancerType, ref);
for (ProcessorType processorType : getOutputs()) {
// The outputs should be the SendProcessor
SendProcessor processor = (SendProcessor) processorType.createProcessor(routeContext);
loadBalancer.addProcessor(processor);
}
After Change
LoadBalancer loadBalancer = LoadBalancerType.getLoadBalancer(routeContext, loadBalancerType, ref);
for (ProcessorType processorType : getOutputs()) {
// The outputs should be the SendProcessor
Processor processor = processorType.createProcessor(routeContext);
processor = processorType.wrapProcessorInInterceptors(routeContext, processor);
loadBalancer.addProcessor((SendProcessor)processor);
}